package com.yide.myworld.service;

import com.yide.myworld.domain.MqDataDto;

/**
 * @auth: byebyebye
 * @date: 2023/3/7 4:56 PM
 * @description:
 */
public interface RocketMQService {
    /**
     * 同步发送mq消息
     * @param topic
     * @param mqDto
     */
    void syncSend(String topic, MqDataDto mqDto);

    /**
     * 同步发送mq消息
     * @param topic
     * @param object
     */
    void syncSend(String topic, Object object);


    /**
     * 异步发送mq消息
     * @param topic
     * @param mqDto
     * @param timeout
     * @param delayLevel
     */
    void asyncSend(String topic, MqDataDto mqDto , long timeout, int delayLevel);
}
